package com.jvup.common.concurrent;


/**
 * 程序工人
 * @param <T> 处理数据类型
 */
public class Worker<T> {

    /** 处理程序 */
//    private final Observed<T> observed;
    /** 调度器 */
    private final Scheduler scheduler;

    Worker(Scheduler scheduler) {
        this.scheduler = scheduler;
    }

//    public void

}
